package db

// 新建任务模板
func (m *MysqlStruct) NewJobModel(j *JobModel) error {
	//tx := m.Db.Begin()
	tx:=m.Db
	if err := tx.Create(&j).Error;err!=nil{
		//tx.Rollback()
		return err
	}
	//tx.Commit()
	return nil
}
// 通过模板的id来更新任务模板
func (m *MysqlStruct) UpdateJobModelByJobIdANdInstance(id int,updates map[string]interface{}) error{
	//db := m.Db.Begin()
	db := m.Db
	obj := JobModel{}
	if err := db.Model(obj).Where("id = ?",id).Updates(updates).Error;err != nil{
		//db.Rollback()
		return err
	}
	//db.Commit()
	return nil
}

// 查询出一个服务的所有任务模板
func (m *MysqlStruct)GetJobModelByServers(serverName string,j *[]JobModel) error {
	//tx := m.Db.Begin()
	tx := m.Db
	err := tx.Where(&JobModel{ServerName: serverName}).Find(&j).Error
	return err
}

// 通过ID查询出一个任务模板
func (m *MysqlStruct)GetJobModelById(id int,j *JobModel) error {
	//tx := m.Db.Begin()
	tx := m.Db
	err := tx.First(&j,id).Error
	return err
}
